package process

import (
	"code.project.com/chatroom/client/utils"
	"code.project.com/chatroom/common/message"
	"encoding/json"
	"fmt"
)

type SmsProcess struct {

}

// 发送群聊的消息
func (s *SmsProcess)SendGroup(content string) (err error){
	// 1. 创建一个mes
	var mes message.Message
	mes.Type = message.SmsMesType

	// 2. 创建一个SmsMes 实例
	var smsMes message.SmsMes
	smsMes.Content = content  // 发送的内容
	smsMes.UserId = currentUser.UserId  // 用户
	smsMes.UserStatus = currentUser.UserStatus  // 状态

	// 3. 序列化smsMes
	data, err := json.Marshal(smsMes)
	if err != nil {
		fmt.Println("SendGroupMes json.Mashal failed = ",err.Error())
	}

	// 4.
	mes.Data = string(data)

	// 5. 序列化要发送的消息体
	data, err = json.Marshal(mes)
	if err != nil {
		fmt.Println("SendGroupMes json.Mashal failed = ",err.Error())
	}

	// 将 mes 发送给服务器
	tf := utils.Transfer{
		Conn:currentUser.Conn,
	}
	err = tf.WritePkg(data)
	if err != nil {
		fmt.Println("SendGroupMes write failed err=", err)
		return
	}
	return
}

